package com.galeno.day03.transfer;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @author galeno
 * @Title:
 * @Description:
 * @date 2021/10/1722:22
 */
public class JDBCSink {
    static class Book {
        final Long id;
        final String title;
        final String authors;
        final Integer year;

        public Book(Long id, String title, String authors, Integer year) {
            this.id = id;
            this.title = title;
            this.authors = authors;
            this.year = year;

        }

    }

    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
//        env.fromElements(
//                new Book(1L,"三国","罗贯中",2019),
//                new Book(2L,"四国","张三",2020),
//                new Book(3L,"五国","李四",2021),
//                new Book(4L,"六国","王五",2022)
//        )
//

    }
}
